﻿#pragma once

#include <string>
#include <hadoop/Closable.h>

namespace HadoopPipes {

	/**
	* For applications that want to read the input directly for the map function
	* they can define RecordReaders in C++.
	*/
	class RecordReader: public Closable {
	public:
		virtual bool next(std::string& key, std::string& value) = 0;

		/**
		* The progress of the record reader through the split as a value between
		* 0.0 and 1.0.
		*/
		virtual float getProgress() = 0;
	};

}